type google.golang.org/grpc/internal/transport.http2Client
40 uses
google.golang.org/grpc/internal/transport (current package)
client_stream.go#L34: ct *http2Client
http2_client.go#L69: type http2Client struct {
http2_client.go#L323: t := &http2Client{
http2_client.go#L481: func (t *http2Client) newStream(ctx context.Context, callHdr *CallHdr) *ClientStream {
http2_client.go#L519: func (t *http2Client) getPeer() *peer.Peer {
http2_client.go#L529: func (t *http2Client) outgoingGoAwayHandler(g *goAway) (bool, error) {
http2_client.go#L539: func (t *http2Client) createHeaderFields(ctx context.Context, callHdr *CallHdr) ([]hpack.HeaderField, error) {
http2_client.go#L640: func (t *http2Client) createAudience(callHdr *CallHdr) string {
http2_client.go#L655: func (t *http2Client) getTrAuthData(ctx context.Context, audience string) (map[string]string, error) {
http2_client.go#L682: func (t *http2Client) getCallAuthData(ctx context.Context, audience string, callHdr *CallHdr) (map[string]string, error) {
http2_client.go#L738: func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr) (*ClientStream, error) {
http2_client.go#L927: func (t *http2Client) closeStream(s *ClientStream, err error, rst bool, rstCode http2.ErrCode, st *status.Status, mdata map[string][]string, eosReceived bool) {
http2_client.go#L991: func (t *http2Client) Close(err error) {
http2_client.go#L1067: func (t *http2Client) GracefulClose() {
http2_client.go#L1090: func (t *http2Client) write(s *ClientStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
http2_client.go#L1120: func (t *http2Client) getStream(f http2.Frame) *ClientStream {
http2_client.go#L1130: func (t *http2Client) adjustWindow(s *ClientStream, n uint32) {
http2_client.go#L1139: func (t *http2Client) updateWindow(s *ClientStream, n uint32) {
http2_client.go#L1148: func (t *http2Client) updateFlowControl(n uint32) {
http2_client.go#L1169: func (t *http2Client) handleData(f *http2.DataFrame) {
http2_client.go#L1238: func (t *http2Client) handleRSTStream(f *http2.RSTStreamFrame) {
http2_client.go#L1265: func (t *http2Client) handleSettings(f *http2.SettingsFrame, isFirst bool) {
http2_client.go#L1314: func (t *http2Client) handlePing(f *http2.PingFrame) {
http2_client.go#L1327: func (t *http2Client) handleGoAway(f *http2.GoAwayFrame) error {
http2_client.go#L1408: func (t *http2Client) setGoAwayReason(f *http2.GoAwayFrame) {
http2_client.go#L1422: func (t *http2Client) GetGoAwayReason() (GoAwayReason, string) {
http2_client.go#L1428: func (t *http2Client) handleWindowUpdate(f *http2.WindowUpdateFrame) {
http2_client.go#L1436: func (t *http2Client) operateHeaders(frame *http2.MetaHeadersFrame) {
http2_client.go#L1619: func (t *http2Client) readServerPreface() error {
http2_client.go#L1635: func (t *http2Client) reader(errCh chan<- error) {
http2_client.go#L1710: func (t *http2Client) keepalive() {
http2_client.go#L1795: func (t *http2Client) Error() <-chan struct{} {
http2_client.go#L1799: func (t *http2Client) GoAway() <-chan struct{} {
http2_client.go#L1803: func (t *http2Client) socketMetrics() *channelz.EphemeralSocketMetrics {
http2_client.go#L1810: func (t *http2Client) RemoteAddr() net.Addr { return t.remoteAddr }
http2_client.go#L1812: func (t *http2Client) incrMsgSent() {
http2_client.go#L1819: func (t *http2Client) incrMsgRecv() {
http2_client.go#L1826: func (t *http2Client) getOutFlowWindow() int64 {
http2_client.go#L1841: func (t *http2Client) stateForTesting() transportState {
logging.go#L38: func prefixLoggerForClientTransport(p *http2Client) *internalgrpclog.PrefixLogger {